package cn.lili.common.thread;

import cn.lili.common.properties.ThreadProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

/**
 * 多线程配置
 *
 * @author Chopper
 * @version v1.0
 * @since 2020-03-12 10:50 上午
 */
@Configuration
public class ThreadConfig implements AsyncConfigurer {

	@Autowired
	private ThreadProperties threadProperties;

	@Override
	public Executor getAsyncExecutor() {
		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
		// 核心线程数，默认为5
		executor.setCorePoolSize(threadProperties.getCorePoolSize());
		// 最大线程数，默认为10
		executor.setMaxPoolSize(threadProperties.getMaxPoolSize());
		// 队列最大长度，一般需要设置值为足够大
		executor.setQueueCapacity(threadProperties.getQueueCapacity());
		// 线程池维护线程所允许的空闲时间，默认为60s
		executor.setKeepAliveSeconds(threadProperties.getKeepAliveSeconds());
		// 允许超时关闭
		executor.setAllowCoreThreadTimeOut(threadProperties.getAllowCoreThreadTimeOut());
		executor.initialize();
		return executor;
	}
}
